package cn.lsh.kafka.db.entity;

import java.io.Serializable;
import java.util.Date;

/**
 * kafka偏移量(Offset)实体类
 *
 * @author makejava
 * @since 2020-12-08 14:33:10
 */
public class OffsetEntity implements Serializable {
    private static final long serialVersionUID = 228985855212725051L;
    
    private Integer id;
    /**
    * 消费者组
    */
    private String groupId;
    /**
    * 主题
    */
    private String topic;
    /**
    * 分区
    */
    private Integer partitionId;
    /**
    * 偏移量
    */
    private Long value;

    private Date createDate;

    private Date updateDate;

    public Date getUpdateDate() {
        return updateDate;
    }

    public void setUpdateDate(Date updateDate) {
        this.updateDate = updateDate;
    }

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getGroupId() {
        return groupId;
    }

    public void setGroupId(String groupId) {
        this.groupId = groupId;
    }

    public String getTopic() {
        return topic;
    }

    public void setTopic(String topic) {
        this.topic = topic;
    }

    public Integer getPartitionId() {
        return partitionId;
    }

    public void setPartitionId(Integer partitionId) {
        this.partitionId = partitionId;
    }

    public Long getValue() {
        return value;
    }

    public void setValue(Long value) {
        this.value = value;
    }

    public Date getCreateDate() {
        return createDate;
    }

    public void setCreateDate(Date createDate) {
        this.createDate = createDate;
    }

    @Override
    public String toString() {
        return "OffsetEntity{" +
                "id=" + id +
                ", groupId='" + groupId + '\'' +
                ", topic='" + topic + '\'' +
                ", partitionId=" + partitionId +
                ", value=" + value +
                ", createDate=" + createDate +
                ", updateDate=" + updateDate +
                '}';
    }
}
